java mysql预处理

[java]代码库import java.sql.*;

import java.util.*;

public class Example14_9 {

public static void main(String args[]) {

SequencePrepareQuery query=new SequencePrepareQuery();

String datasorce="star";

String tableName="employee";

query.setDatasourceName(datasorce);

query.setTableName(tableName);

ArrayList result=query.getQueryResult();

for(StringBuffer str:result) {

System.out.println(str);

}

}

}

import java.sql.*;

import java.util.*;

public class PreparedQuery {

String datasourceName=""; //数据源名

String tableName=""; //表名

String SQL; //SQL语句

ArrayList queryResult; //查询结果

public PreparedQuery() {

try{ Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

}

catch(ClassNotFoundException e) {

System.out.print(e);

}

}

public void setDatasourceName(String s) {

datasourceName=s.trim();

}

public void setTableName(String s) {

tableName=s.trim();

}

public void setSQL(String SQL) {

this.SQL=SQL;

}

public ArrayList getQueryResult() {

queryResult=new ArrayList();

Connection con;

Statement sql;

ResultSet rs;

try {

String uri="jdbc:odbc:"+datasourceName;

String id="";

String password="";

con=DriverManager.getConnection(uri,id,password);

DatabaseMetaData metadata=con.getMetaData();

ResultSet rs1=metadata.getColumns(null,null,tableName,null);

int 字段个数=0;

while(rs1.next()) {

字段个数++;

}

sql=con.prepareStatemen(SQL);

rs=sql.executeQuery();

while(rs.next()) {

StringBuffer record=new StringBuffer();

for(int k=1;k

System.out.println("请输入正确的表名"+e);

}

return queryResult;

}

}

import java.sql.*;

import java.util.*;

public class PrepareQuery {

String datasourceName=""; //数据源名

String tableName=""; //表名

String SQL; //SQL语句

ArrayList queryResult; //查询结果

public PrepareQuery() {

try{ Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

}

catch(ClassNotFoundException e) {

System.out.print(e);

}

}

public void setDatasourceName(String s) {

datasourceName=s.trim();

}

public void setTableName(String s) {

tableName=s.trim();

}

public void setSQL(String SQL) {

this.SQL=SQL;

}

public ArrayList getQueryResult() {

queryResult=new ArrayList();

Connection con;

PreparedStatement sql;

ResultSet rs;

try {

String uri="jdbc:odbc:"+datasourceName;

String id="";

String password="";

con=DriverManager.getConnection(uri,id,password);

DatabaseMetaData metadata=con.getMetaData();

ResultSet rs1=metadata.getColumns(null,null,tableName,null);

int 字段个数=0;

while(rs1.next()) {

字段个数++;

}

sql=con.prepareStatement(SQL);

rs=sql.executeQuery();

while(rs.next()) {

StringBuffer record=new StringBuffer();

for(int k=1;k

System.out.println("请输入正确的表名"+e);

}

return queryResult;

}

}

import java.sql.*;

import java.util.*;

public class SequencePrepareQuery extends PrepareQuery {

public ArrayList getQueryResult() {

setSQL("SELECT * FROM "+tableName);

return super.getQueryResult();

}

}